package ihuotui.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class pool {
    public static void main(String[] args) {
        // 创建一个可重用固定线程数的线程池
           ExecutorService pool = Executors.newFixedThreadPool(2);
           for (int i = 0; i < 1000; i++) {
               // 创建实现了Runnable接口对象，Thread对象当然也实现了Runnable接口
               Thread t1 = new MyThread();
               // 将线程放入池中进行执行
               pool.execute(t1);
           }
           // 关闭线程池
//         pool.shutdown();

       }
   }
   class MyThread extends Thread {
       @Override
       public void run() {
           try {
               Thread.currentThread().sleep(1*1000);
           } catch (InterruptedException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
           }
       System.out.println(Thread.currentThread().getName() + "正在执行。。。");
       }
   }